//package com.open.pokergames.conn;
//
//import android.util.Log;
//
//import com.alibaba.fastjson.JSON;
//import com.open.pokergames.comm.repository.NetConfig;
//import com.open.pokergames.conn.entity.Message;
//import com.sinothk.android.utils.XUtils;
//
//import org.greenrobot.eventbus.EventBus;
//
//import java.net.URISyntaxException;
//
//import io.socket.client.IO;
//import io.socket.client.Socket;
//import io.socket.emitter.Emitter;
//
//public class SocketManager {
//
//
//    protected static String TAG = "SocketManager";
//    private static Socket mSocket;
//
//    public static void start(String account) {
//        try {
//            IO.Options opts = new IO.Options();
//            opts.query = "loginUserNum=" + account;
//            mSocket = IO.socket(NetConfig.SOCKET_URL, opts);//这里的地址我们用后台提供的 //"http://192.168.0.32:9099"
//            mSocket.on("connect", new Emitter.Listener() {
//                // 链接成功回调监听
//                @Override
//                public void call(Object... args) {
//                    Log.e(TAG, "链接成功");
//                }
//            });
//
//            mSocket.on("disconnect", new Emitter.Listener() {
//                // 消息接收回调监听
//                @Override
//                public void call(final Object... args) {
//                    Log.e(TAG, "disconnect");
//                }
//            });
////            mSocket.on("event", new Emitter.Listener() {
////                // 消息接收回调监听
////                @Override
////                public void call(final Object... args) {
////                    Log.e(TAG, args[0].toString());
////                }
////            });
//            setListener(mSocket);
//
//            mSocket.connect();
//        } catch (URISyntaxException e) {
//            e.printStackTrace();
//        }
//    }
//
//    private static void setListener(Socket mSocket) {
//
//        // 消息接收回调监听
//        mSocket.on(Message.TYPE_ROOM, args -> {
//            Log.e(TAG, "TYPE_ROOM 消息" + args[0].toString());
//            post(args[0].toString());
//        });
//
//        mSocket.on(Message.TYPE_PERSON, args -> {
//            Log.e(TAG, "TYPE_PERSON 消息" + args[0].toString());
//            post(args[0].toString());
//        });
//        mSocket.on(Message.TYPE_GROUP, args -> {
//            Log.e(TAG, "TYPE_GROUP 消息" + args[0].toString());
//            post(args[0].toString());
//        });
//        mSocket.on(Message.TYPE_CLUB, args -> {
//            Log.e(TAG, "TYPE_CLUB 消息" + args[0].toString());
//            post(args[0].toString());
//        });
//        mSocket.on(Message.TYPE_BROADCAST, args -> {
//            Log.e(TAG, "TYPE_BROADCAST 消息" + args[0].toString());
//            post(args[0].toString());
//        });
//    }
//
//    private static void post(String msgStr) {
//        Message msg = JSON.parseObject(msgStr, Message.class);
//        EventBus.getDefault().post(msg);
//    }
//
////    protected void sendTxt(String msg) {
////        mSocket.emit("event", "{\"loginUserNum\":\"123\"}");//"终于发过去了"
////    }
//
//    public static void stop() {
//        if (mSocket != null) {
//            mSocket.off();
//            mSocket.disconnect();
//        }
//    }
//
//    public static void sendMsg(String msgType, Message message) {
//        if (mSocket != null && mSocket.connected()) {
//            mSocket.emit(msgType, JSON.toJSONString(message));//"终于发过去了"
//        } else {
//            XUtils.toast().show("当前处于离线状态");
//        }
////        mSocket.emit("event", message);//"终于发过去了"
//    }
//}
